package com.example.consumer.receiver;

import com.example.consumer.config.RabbitConfig;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class MsgReceiver {
//即便关闭了consumer，只要publisher发布了，因为开了持久化，所以就会暂存到rabbitmq中。等consumer上线（开启服务）就会消费
//如果consumer没消费，consumer的queue中的消息状态会被标记为“ready”。
//如果consumer消费了，但是没有给publisher发送ack，消息会被标记为“unacked”
    @RabbitListener(queues = RabbitConfig.QUEUE_NAME)
    public void handleMsg(String msg){
        System.out.println(msg);
    }

}
